package com.huwei.activemq.mq;

import org.springframework.jms.annotation.JmsListener;
import org.springframework.messaging.handler.annotation.SendTo;
import org.springframework.stereotype.Component;

/**
 * @Author: 胡伟
 * @Date: 2021/1/14 10:07
 * @Description:
 */
@Component
public class ActiveMQConsumer {
    /**
     * 处理消息
     * @param msg
     * @return
     */
    //destination 为消费哪个queue
    @JmsListener(destination = "huwei_queue")
    //sendTo为会将此方法的放回数据放入到完成消费的消息里面去
    @SendTo("out_queue")
    public String handlingHuwei(String msg){
        System.out.println(Thread.currentThread().getName()+"-----"+Thread.currentThread().getThreadGroup());
        System.out.println("消费了一条消息,消费是:"+msg);
        return "我成功的消费了一条消息,消息为"+msg;
    }
    //destination 为消费哪个queue
    @JmsListener(destination = "jiahong_queue")
    //sendTo为会将此方法的放回数据放入到完成消费的消息里面去
    @SendTo("out_queue")
    public String handingJiahong(String msg){
        System.out.println("消费了一条消息,消费是:"+msg);
        return "我成功的消费了一条消息,消息为"+msg;
    }
}
